from celery import Celery

# 我们这里案例使用redis作为broker
app = Celery(
    'demo',
    broker='redis://127.0.0.1:6379/5',
    backend='redis://127.0.0.1:6379/6'
)


# 创建任务函数
@app.task
def my_task(a, b):
    print("任务函数正在执行....")
    return a + b
